package com.oh.core.common.base;

import com.oh.core.entity.MessageEntity;
import io.netty.channel.ChannelHandlerContext;

/**
 * 消息处理接口
 * 对外开放接口，业务调用处理对应信息
 */
public interface MessageService {

    /**
     * 业务处理
     * @param ctx
     * @param msg
     * @return
     */
    int handle(ChannelHandlerContext ctx, MessageEntity msg);
}
